#include "Consumer.hpp"
#include "TaskQueue.hpp"

#include <pthread.h>
#include <unistd.h>
#include <stdio.h>


namespace wd{

Consumer::Consumer(TaskQueue & taskque)
:_taskque(taskque){
    
}

void Consumer::run(){

    sleep(5);
    
    for(int i = 0; i< 10; ++i){
        int num = _taskque.pop();
        pthread_t pthid = pthread_self(); 
        printf("线程id:%ld, 消费商品 %d \n",pthid%10,num);
        sleep(1);
    }
}

}

